package com.windy.kafka.sender.annotation.producer;

import org.apache.kafka.clients.producer.ProducerRecord;

/**
 * Created by liyufeng on 2022/3/26
 * 发送MQ消息前，回调处理消息
 */
public interface MessageSendPostProcessor<K, V> {
    /**
     * 发送消息前回调处理
     *
     * @param
     */
    void postProcessMessage(ProducerRecord<K, V> record);
}
